package org.zhadoop.streaming.operator.inputstream;

import org.zhadoop.streaming.operator.IInputStreamOperator;

/**
 * 基于Kafka 的处理，完成Storm 中的spout 功能
 * @author zwd
 *
 */
public class KafkaSourceOp implements IInputStreamOperator{

	/**
	 * 
	 */
	private static final long serialVersionUID = 2936378150062844907L;

	
	
}
